#pragma once
#define CLOUD_QUEUE "/clout_queue"
#define CTRL_QUEUE "/ctrl_queue"
#define SERVICE_QUEUE_RSP "/service_queue_rsp"
#define SERVICE_QUEUE_REQ "/service_queue_req"
#define AIR_DEV_QUEUE "/air_dev_queue"

int send_msg(const char *qname, const char *msg, int len, int flag = 0, int prio = 0);
int recv_msg(const char *qname, char *buf, int len, int flag = 0);
int timerecv_msg(const char *qname, char *buf, int len, int timeout = 5);